package controller

import (
	"kafkademo/pkg/meta"
	"net/http"

	"github.com/gin-gonic/gin"
	"github.com/illidaris/aphrodite/dto"
)

func MsgsHandler(c *gin.Context) {
	c.JSON(http.StatusOK, dto.OkResponse(meta.DefaultDB.All()))
}
